package com.atguigu.rpc;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;

import java.io.IOException;
import java.net.InetSocketAddress;

import static java.lang.System.*;

/**
 * @description: xxx
 * @time: 2021/3/26 10:16
 * @author: baojinlong
 **/
public class HdfsClient {
    public static void main(String[] args) throws Exception {
        // 获取客户端对象
        RpcProtocol client = RPC.getProxy(RpcProtocol.class, RpcProtocol.VERSION_ID, new InetSocketAddress("localhost", 8888),
                new Configuration());
        out.println("客户端开始i工作");
        client.mkDirs("/xx");
    }
}
